import pika
#与RabbitMQ建立连接
connection = pika.BlockingConnection(
    pika.ConnectionParameters(host='localhost'))#连接到本地机器上的代理-localhost,如果我们想连接到另一台机器上的代理，我们只需在此处指定其名称或IP地址
channel = connection.channel()

channel.queue_declare(queue='hello')#在发送之前，我们需要确保接受方队列存在。如果我们向不存在的位置发送消息，RabbitMQ只会丢弃该消息，所以创建一个消息将被传递到hello队列

channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')#routing_key允许我们指定消息去哪个队列
print(" [x] Sent 'Hello World!'")
connection.close()

